const Koa = require('koa')
const bodyParser = require('koa-bodyparser')
const _ = require('koa-route')
// mysql
const mysql = require('koa-mysql')

const app = new Koa()
app.listen(3000, () => console.log('http://localhost:3000'))
app.use(bodyParser())

// 连接数据库 数据库连接池
const db = mysql.createPool({
  // mysql连接的主机地址
  host: 'localhost',
  // mysql连接账号
  user: 'root',
  // mysql连接密码
  password: 'root',
  // 数据库名
  database: 'test',
  // 连接池中的连接对象要创建几个
  connectionLimit: 2
})


app.use(_.get('/users', async ctx => {

  let p = new Promise((resolve, reject) => {
    let sql = 'select * from users'
    db.query(sql)(function (err, data) {
      if (!err) {
        resolve(data)
      } else {
        reject(err)
      }
    })
  })

  ctx.body = await p
}))